package org.apache.lorry.demo;

import org.apache.lorry.util.clusters.EmbeddedKafkaCluster;

import java.util.Properties;

public class EmbeddedKafkaClusterDemo {
    public static void main(String[] args) {
        Properties brokerProps;
        brokerProps = new Properties();
        brokerProps.put("transaction.state.log.replication.factor", "1");
        brokerProps.put("transaction.state.log.min.isr", "1");
        brokerProps.put("listeners", "PLAINTEXT://localhost:9092");
        EmbeddedKafkaCluster embeddedKafkaCluster = new EmbeddedKafkaCluster(1, brokerProps);
        embeddedKafkaCluster.start();
    }
}